# ==============================================
# 导入层
# ==============================================


from .config import initialize_config                               # 导入配置模块
from .strangers_handle import handle_stranger_message               # 导入陌生人消息处理模块
from .message_handle import process_unread_xiaohongshu_messages     # 导入常规消息处理模块
from .send_message_handle import handle_feishu_task                 # 导入消息发送模块
import time                                                         # 时间操作模块（用于延时、计时等）

# from .cs import *                                                   # 导入测试模块


# ==============================================
# 封装层
# ==============================================


# 主程序
def main(access_token,workflow_id,app_token,Scheme_Name,number):
    
    print("主程序调用了！！！")

    # 初始化配置（从配置表中获取配置参数）
    initialize_config(access_token,workflow_id,app_token,Scheme_Name,number)

    #执行测试
    # cs()

    # 无限循环执行消息处理和任务处理
    print("开始执行消息监控和任务处理...")
    try:

        print("\n===== 处理循环开始 =====")

        while True:
            # 调用函数处理陌生人消息
            handle_stranger_message()

            # 调用函数处理常规未读消息
            process_unread_xiaohongshu_messages()

            # 调用函数处理飞书任务
            handle_feishu_task()


            print("本轮处理完成，休眠后继续...")

            # 添加休眠时间，避免过于频繁的循环
            time.sleep(1)  # 休眠后再次执行循环

    except Exception as e:
        error_message = f"执行过程中发生错误: {str(e)}"
        print(error_message)


#==============================================
if __name__ == "__main__":
    main()


